package avicit.bdp.dcs.plugin;

/**
 * @金航数码科技有限责任公司
 * @作者：liyb
 * @邮箱：developer@avic-digital.com
 * @创建时间： 2021-01-21 16:33
 * @类说明：
 * @修改记录：
 */
public final class DataxConstants {

    // 公用
    public static final String NAME = "name";
    public static final String PARAMETER = "parameter";
    public static final String TYPE = "type";
    public static final String READER = "reader";
    public static final String WRITER = "writer";
    public static final String TRANSFORMER = "transformer";
    public static final String SPEED = "speed";
    public static final String ERROR_LIMIT = "errorLimit";
    public static final String CHANNEL = "channel";
    public static final int CHANNEL_SIZE = 10;
    public static final String RECORD = "record";
    public static final String PERCENTAGE = "percentage";
    public static final String SETTING = "setting";
    public static final String CONTENT = "content";
    public static final String JOB = "job";
    public static final String BYTE = "byte";

    // rdbms
    public static final String RDBMS_USERNAME = "username";
    public static final String RDBMS_PASSWORD = "password";
    public static final String RDBMS_QUERY_SQL = "querySql";
    public static final String RDBMS_COLUMN = "column";
    public static final String RDBMS_WHERE = "where";
    public static final String RDBMS_TABLE = "table";
    public static final String RDBMS_SPLIT_PK = "splitPk";
    public static final String RDBMS_JDBC_URL = "jdbcUrl";
    public static final String RDBMS_CONNECTION = "connection";
    public static final String RDBMS_PRE_SQL = "preSql";
    public static final String RDBMS_FETCH_SIZE = "fetchSize";
    public static final int DEFAULT_FETCH_SIZE = 1000;
    public static final String RDBMS_BATCH_SIZE = "batchSize";
    public static final int DEFAULT_BATCH_SIZE = 500;
    public static final String POLICY = "policy";

    // rdbms
    public static final String RDBMS_READER = "rdbmsreader";
    public static final String RDBMS_WRITER = "rdbmswriter";

    // mysql
    public static final String MYSQL_READER = "mysqlreader";
    public static final String MYSQL_WRITER = "mysqlwriter";

    // oracle
    public static final String ORACLE_READER = "oraclereader";
    public static final String ORACLE_WRITER = "oraclewriter";

    // sqlserver
    public static final String SQLSERVER_READER = "sqlserverreader";
    public static final String SQLSERVER_WRITER = "sqlserverwriter";

    // postgresql
    public static final String POSTGRESQL_READER = "postgresqlreader";
    public static final String POSTGRESQL_WRITER = "postgresqlwriter";

    // greenplum
    public static final String GREENPLUM_WRITER = "gpdbwriter";

    // param
    public static final String HIVE_READER = "hdfsreader";
    public static final String HTTP_READER = "httpreader";
    public static final String HIVE_PATH = "path";
    public static final String HIVE_DEFAULTFS = "defaultFS";
    public static final String HIVE_FILE_TYPE = "fileType";
    public static final String HIVE_FIELD_DELIMITER = "fieldDelimiter";
    public static final String HIVE_COLUMN = "column";
    public static final String HIVE_FILENAME = "fileName";
    public static final String HIVE_WRITE_MODE = "writeMode";

    // hdfs
    public static final String HDFS_READER = "hdfsreader";
    public static final String HDFS_PATH = "path";
    public static final String HDFS_DEFAULTFS = "defaultFS";
    public static final String HDFS_FILE_TYPE = "fileType";
    public static final String HDFS_FIELD_DELIMITER = "fieldDelimiter";
    public static final String HDFS_COLUMN = "column";
    public static final String HDFS_ENCODING = "encoding";
    public static final String HDFS_UTF8 = "UTF-8";
    public static final String HDFS_SKIP_HEADER = "skipHeader";
    public static final String HDFS_SKIP_LINES = "skipLines";
    public static final String HDFS_SHEET_TAB = "sheetTab";
    public static final String HDFS_JSON_PATH = "jsonPath";
    public static final String HDFS_HAVE_KERBEROS = "haveKerberos";
    public static final String HDFS_QUOTATION = "quotation";
    public static final String HDFS_SINGLE_QUOTATION = "singleQuotation";
    public static final String HDFS_DOUBLE_QUOTATION = "doubleQuotation";

    public static final String HDFS_WRITER = "hdfswriter";
    public static final String HDFS_FILENAME = "fileName";
    public static final String HDFS_WRITE_MODE = "writeMode";
    public static final String HDFS_HIVE_CONNECTION = "hiveConnection";
    public static final String KERBEROS_PARAM = "kerberosParam";
    public static final String HDFS_PATHS = "paths";
    public static final String HDFS_MAX_FILESIZE = "maxFileSize";
    public static final String HDFS_TBL2_DEVICE_MAP = "tbl2DeviceMap";
    public static final String HDFS_COLUMNS = "columns";
    public static final String HDFS_TASK_TYPE = "taskType";

    // hbase
    public static final String HBASE_READER = "hbase11xreader";
    public static final String HBASE_ZOOKEEPER_QUORUM = "hbase.zookeeper.quorum";
    public static final String HBASE_CONFIG = "hbaseConfig";
    public static final String HBASE_TABLE = "table";
    public static final String HBASE_MODE = "mode";
    public static final String HBASE_COLUMN = "column";
    public static final String HBASE_RANGE = "range";
    public static final String HBASE_MAX_VERSION = "maxVersion";

    public static final String HBASE_WRITER = "hbase11xwriter";
    public static final String HBASE_VERSION_COLUMN = "versionColumn";
    public static final String HBASE_ROWKEY_COLUMN = "rowkeyColumn";

    // kafka
    public static final String KAFKA_READER = "kafkareader";
    public static final String KAFKA_TOPIC = "topics";
    public static final String KAFKA_SERVERS = "servers";
    public static final String KAFKA_PARTITIONS = "kafkaPartitions";
    public static final String KAFKA_MSGID = "msgId";
    public static final String KAFKA_MSG_SERIALIZE_TYPE = "msgSerializeType";
    public static final String KAFKA_COMPANY = "company";
    public static final String KAFKA_DEFAULT = "default";
    public static final String KAFKA_PARAS = "paras";
    public static final String KAFKA_GROUP_ID = "groupId";
    public static final String KAFKA_AUTO_OFFSET_REST = "autoOffestRest";

    // iotdb
    public static final String IOTDB_WRITER = "iotdbwriter";
    public static final String IOTDB_BOOTSTRAP_SERVERS = "bootstrapServers";
    public static final String IOTDB_USERNAME = "username";
    public static final String IOTDB_PASSWORD = "password";
    public static final String IOTDB_BATCH_SIZE = "batchSize";
    public static final String IOTDB_PRE_SQL = "preSql";
    public static final String IOTDB_DEVICEID = "deviceId";
    public static final String IOTDB_PARAS = "paras";
    public static final String IOTDB_KAFKA_2IOT_MAP = "kafka2IotMap";
    public static final String IOTDB_COLUMNS = "columns";

    // mongodb
    public static final String MONGODB_READER = "mongodbreader";
    public static final String MONGODB_WRITER = "mongodbwriter";

    // oss
    public static final String OSS_READER = "bdpossreader";
    public static final String OSS_ENDPOINT = "endpoint";
    public static final String OSS_ACCESSID = "accessId";
    public static final String OSS_ACCESS_KEY = "accessKey";
    public static final String OSS_BUCKET = "bucket";
    public static final String OSS_FILE_TYPE = "fileType";
    public static final String OSS_FIELD_DELIMITER = "fieldDelimiter";
    public static final String OSS_OBJECT = "object";
    public static final String OSS_COLUMN = "column";

    // odps
    public static final String ODPS_READER = "odpsreader";
    public static final String ODPS_WRITER = "odpswriter";
    public static final String ODPS_PROJECT = "project";
    public static final String ODPS_TABLE = "table";
    public static final String ODPS_PARTITION = "partition";
    public static final String ODPS_COLUMN = "column";
    public static final String ODPS_ACCESSID = "accessId";
    public static final String ODPS_ACCESSKEY = "accessKey";
    public static final String ODPS_TRUNCATE = "truncate";
    public static final String ODPS_SERVER = "odpsServer";
    public static final String ODPS_TUNNEL_SERVER = "tunnelServer";
    public static final String ODPS_ACCOUNT_TYPE = "accountType";
    public static final String ODPS_PACKAGE_AUTHORIZED_PROJECT = "packageAuthorizedProject";
    public static final String ODPS_SPLIT_MODE = "splitMode";

    // 其他
    public static final String STRING = "string";
    public static final String INDEX = "index";
    public static final String SPLIT_SCOLON = ":";
    public static final String DEFAULT_DEVICEID = "root.182.";

}
